package com.xiaoxu.spark

import org.apache.spark.sql.hive.HiveContext
import org.apache.spark.{SparkConf, SparkContext}

/**
  *
  * author: zhangXu
  * http://spark.apache.org/docs/latest/submitting-applications.html
  * 使用时需要通过--jars 把mysql的驱动传递到classpath
  *
  * spark-submit \
  * --name HiveContextDemo \
  * --class com.xiaoxu.spark.HiveContextDemo \
  * --master local[2] \
  * --jar drivePath \
  * /home/hadoop/lib/sql-1.0.jar \
  *
  **/
object HiveContextDemo {
  def main(args: Array[String]) {
    //1)创建相应的Context
    val sparkConf = new SparkConf()

    //在测试或者生产中，AppName和Master我们是通过脚本进行指定
    sparkConf.setAppName("HiveContextDemo").setMaster("local[2]")

    val sc = new SparkContext(sparkConf)
    val hiveContext = new HiveContext(sc)

    //2)相关的处理:
    hiveContext.table("dept").show

    //3)关闭资源
    sc.stop()
  }
}
